package org.example.message_queue.common;

import org.example.message_queue.mqserver.core.BasicProperties;

import java.io.IOException;

//     单纯的函数式回调接口
@FunctionalInterface
public interface Consumer {
    void handleDelivery(String consumerTag, BasicProperties basicProperties,byte[] body) throws MqException, IOException;
}
